package com.ruoyi.web.controller.mqtt;

import lombok.Data;

import java.util.concurrent.atomic.AtomicLong;


/**
 * mqtt 消息类型
 *
 * @author hwf
 * 2022-08-10
 */
@Data
public class Request {

    private static final long serialVersionUID = 1L;


    private static final AtomicLong INVOKE_ID = new AtomicLong(0);

    private  String mId;
    private  String msg;


    private Object data;


    public Request(String id) {
        mId = id;
    }

    private static long newId() {
        return INVOKE_ID.getAndIncrement();
    }
}
